package com.hadoop;

import org.apache.spark.api.java.JavaSparkContext;

public class HadoopRDD {
    String sstFilePath = "hdfs://<namenode>:<port>/<path-to-sst>";
    Configuration conf = new Configuration();
    JavaSparkContext jsc = new JavaSparkContext(sparkConf);
    JavaPairRDD<ImmutableBytesWritable, byte[]> rdd = jsc.newAPIHadoopFile(
            sstFilePath
            , RocksDBInputFormat.class
            , ImmutableBytesWritable.class
            , byte[].class, conf);
    
}
